import org.junit.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;
import java.io.IOException;

public class Demo2 {
    /**
     * 管道操作
     */
    @Test
    public void test() throws IOException {
        //按照面向对象思想，我们要想使用jedis，要么就是提供了对象创建，要么就是静态方法
        //创建jedis对象
        Jedis jedis = new Jedis("127.0.0.1",6379);
        //创建管道对象
        Pipeline pipeline = jedis.pipelined();
        //获取到当前的系统时间
        long start = System.currentTimeMillis();
        //建立管道jedis循环
        for (int i = 0; i < 200000; i++) {
            pipeline.set("key" + i, "value" + i);
        }
        //关闭管道
        pipeline.close();
        //获取结束时间
        long end  = System.currentTimeMillis();
        //输出时间
        System.out.println(end - start);
        //关闭jedis
        jedis.close();
    }
}
